import { SseClient } from './sse';

// SSE 服务器地址（从环境变量读取，与HTTP API使用相同的基地址）
const baseUrl = import.meta.env.VITE_HTTP_BASE || '/dev-api'; // 对应后端 /sse 接口的基础路径

// SSE 客户端配置
const options = {
  baseUrl: baseUrl,
  reconnectPeriod: 5000 // 重连间隔（毫秒）
};

const sse = new SseClient(baseUrl, options);

// 订阅主题（类似原来的 MQTT subscribe）
// 支持通配符：'#' 匹配多级，'+' 匹配单级
// sse.subscribe(['frontend/#', 'topology/#'], (topic, data) => {
//   console.log('Received from topic:', topic, data);
// });

// 设置特定主题的消息回调（类似原来的 message_callback）
// sse.message_callback('frontend/#', (topic, data) => {
//   console.log('Frontend topic:', topic, data);
// });

// 手动连接（可选，subscribe 时如果未连接会自动连接）
// sse.connect();

export default sse;

